package com.celeritymq.server.buffer;

import javax.jms.Destination;

import com.celeritymq.destination.CelerityTemporaryTopic;
import com.celeritymq.destination.CelerityTopic;

/**
 * 
 * @author max
 * 用来缓冲topic消息
 */
public interface TopicBuffer{

	public void addToHead(CelerityTopic topic);

	public void addToTail(CelerityTopic topic);

	public CelerityTopic pollTopic();
	
	public void addToHead(CelerityTemporaryTopic topic);

	public void addToTail(CelerityTemporaryTopic topic);

	public CelerityTemporaryTopic pollTemporaryTopic();

}
